package com.dduggs.rocketmq;

import com.alibaba.rocketmq.client.consumer.listener.*;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

import java.io.*;
import java.util.*;

@Data
@NoArgsConstructor
@ToString(callSuper=true)
public class MsgObj implements Serializable{

	/**
	 * 消息 id
	 */
	private String msgId;

	/**
	 * 重试次数
	 */
	private int reConsumeTimes;

	/**
	 * 消息
	 */
	List<Serializable> msgList;

	/**
	 * 错误信息
	 */
	private String errorMsg;

    /**
     * context
     */
	private ConsumeConcurrentlyContext context;

}